package com.ruleengine.coordinator;

import java.util.concurrent.CompletableFuture;

public interface ICoordinator {
    void start();

    CompletableFuture<Void> sub(String topicFilter);

    CompletableFuture<Void> unsub(String topicFilter);

    void close();
}
